package com.gagakuai.bpm.mqlistener.camunda.baseproxy;


import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;

@FunctionalInterface
public interface BaseConsumer {


    /*
     * @param channel 通道
     * @param message 消息
     * @return
     * @Author houhong
     * @Description //TODO 实际类消费消息
     * @Date 11:00 上午 2022/3/25
     */
    public void consume(Message message, Channel channel,String messageType) throws Exception;
}
